package com.hl.card.mq;

import com.hl.card.common.mq.QueueConfig;

import java.util.HashMap;
import java.util.Map;

/**
 *消息队列配置，这里只能修改值，不可以增删改变量
 */
public class MqCustomConfig {
    public static final String QUEUE_UNFREEZE= "queue.notify.mch.unfreeze";
    //===================================common普通消息队列=====================================
    //这个通道是专门用于支付中心在解冻订单后异步回传解冻结果的
    public static final String PAY_NOTIFY_UNFREEZE_QUEUE = "queue.notify.pay.unfreeze";
    public static final String QUEUE_AWARD= "queue.award";
    public static final String QUEUE_AWARD_API= "queue.award.api";
    public static final String QUEUE_DELAY_STATUS= "queue.delay.status";
    //注意，不要修改QUEUE_DEFINE的变量名称，只能修改初始化值
    //经过初始化后的每个通道都自动配置了一个应答通道，用于将消息异步处理的结果同步给消息发送者，便于根据处理结果来做进一步的行动
    public static final Map<String, QueueConfig> QUEUE_DEFINE;
    static {
        QUEUE_DEFINE = new HashMap<String, QueueConfig>();
        QUEUE_DEFINE.put(PAY_NOTIFY_UNFREEZE_QUEUE, QueueConfig.NORMAL);
        QUEUE_DEFINE.put(QUEUE_AWARD_API, QueueConfig.NORMAL);
        QUEUE_DEFINE.put(QUEUE_DELAY_STATUS, QueueConfig.WITH_DELAY);
    }
}